package com.hdfs.api;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

//上传
public class HDFSPutFileDemo {
    public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
         //创建配置类
        Configuration conf = new Configuration();
        //设置hdfs的URI
        URI uri = new URI("hdfs://10.90.100.101:9820");
        //获取文件系统的对象 参数1 hdfs的uri  参数2 配置类对象  参数3 hadoop集群的用户（根据自己实际用填写）
        FileSystem fs = FileSystem.get(uri, conf, "hadoop");
        //设置要从本地上传文件的路径
        Path src = new Path("D:/Program Files/apache-maven-3.9.8.zip");
        //设置要上传到hdfs的目标路径
        Path dst = new Path("/");
        //从本地上传到hdfs
        fs.copyFromLocalFile(src,dst);

    }
}
